[INFO] cloning repository https://github.com/gdrfgdrf/strawberry_background
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/gdrfgdrf/strawberry_background" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgdrfgdrf%2Fstrawberry_background", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgdrfgdrf%2Fstrawberry_background'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 4b7110ec693c77f7c402413d306fdcf48100bdae
[INFO] checking gdrfgdrf/strawberry_background against try#b66808126f24f2f30898306a881e1676824ea80c for pr-133502-23
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgdrfgdrf%2Fstrawberry_background" "/workspace/builds/worker-1-tc2/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-1-tc2/source'...
[INFO] [stderr] done.
[INFO] started tweaking git repo https://github.com/gdrfgdrf/strawberry_background
[INFO] finished tweaking git repo https://github.com/gdrfgdrf/strawberry_background
[INFO] tweaked toml for git repo https://github.com/gdrfgdrf/strawberry_background written to /workspace/builds/worker-1-tc2/source/Cargo.toml
[INFO] validating manifest of git repo https://github.com/gdrfgdrf/strawberry_background on toolchain b66808126f24f2f30898306a881e1676824ea80c
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b66808126f24f2f30898306a881e1676824ea80c" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate git repo https://github.com/gdrfgdrf/strawberry_background already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b66808126f24f2f30898306a881e1676824ea80c" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3d5ced03c013a94a2f102a4510f48a6e9184255caf5fd8244f58017bde7f5210" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0
[INFO] running `Command { std: "docker" "start" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0" "/opt/rustwide/cargo-home/bin/cargo" "+b66808126f24f2f30898306a881e1676824ea80c" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0" "/opt/rustwide/cargo-home/bin/cargo" "+b66808126f24f2f30898306a881e1676824ea80c" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.180
[INFO] [stderr]     Checking bytes v1.11.1
[INFO] [stderr]    Compiling libm v0.2.16
[INFO] [stderr]    Compiling find-msvc-tools v0.1.8
[INFO] [stderr]    Compiling serde_core v1.0.228
[INFO] [stderr]     Checking bytemuck v1.25.0
[INFO] [stderr]    Compiling quote v1.0.45
[INFO] [stderr]     Checking futures-channel v0.3.32
[INFO] [stderr]    Compiling aws-lc-rs v1.15.4
[INFO] [stderr]     Checking rustls-pki-types v1.14.0
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]    Compiling rustls v0.23.36
[INFO] [stderr]    Compiling alsa-sys v0.4.0
[INFO] [stderr]     Checking indexmap v2.13.0
[INFO] [stderr]     Checking rand_core v0.10.1
[INFO] [stderr]    Compiling getrandom v0.4.2
[INFO] [stderr]    Compiling syn v2.0.117
[INFO] [stderr]    Compiling time-core v0.1.8
[INFO] [stderr]    Compiling num-conv v0.2.0
[INFO] [stderr]    Compiling zmij v1.0.16
[INFO] [stderr]    Compiling serde_json v1.0.149
[INFO] [stderr]     Checking chacha20 v0.10.0
[INFO] [stderr]     Checking concurrent-queue v2.5.0
[INFO] [stderr]     Checking sync_wrapper v1.0.2
[INFO] [stderr]     Checking extended v0.1.0
[INFO] [stderr]    Compiling cpal v0.17.3
[INFO] [stderr]     Checking strength_reduce v0.2.4
[INFO] [stderr]     Checking openssl-probe v0.2.1
[INFO] [stderr]     Checking dasp_sample v0.11.0
[INFO] [stderr]    Compiling time-macros v0.2.26
[INFO] [stderr]     Checking symphonia-core v0.5.5
[INFO] [stderr]    Compiling portable-atomic v1.13.1
[INFO] [stderr]     Checking simdutf8 v0.1.5
[INFO] [stderr]     Checking rustls-native-certs v0.8.3
[INFO] [stderr]     Checking unicode-ident v1.0.22
[INFO] [stderr]     Checking rtrb v0.3.4
[INFO] [stderr]     Checking event-listener v5.4.1
[INFO] [stderr]     Checking arc-swap v1.9.1
[INFO] [stderr]     Checking crossbeam-epoch v0.9.18
[INFO] [stderr]     Checking proc-macro2 v1.0.106
[INFO] [stderr]     Checking http v1.4.0
[INFO] [stderr]     Checking id-arena v2.3.0
[INFO] [stderr]     Checking event-listener-strategy v0.5.4
[INFO] [stderr]     Checking hashbrown v0.14.5
[INFO] [stderr]     Checking glam v0.30.10
[INFO] [stderr]     Checking async-lock v3.4.2
[INFO] [stderr]     Checking symphonia-metadata v0.5.5
[INFO] [stderr]     Checking symphonia-codec-aac v0.5.5
[INFO] [stderr]     Checking symphonia-codec-pcm v0.5.5
[INFO] [stderr]     Checking time v0.3.46
[INFO] [stderr]     Checking http-body v1.0.1
[INFO] [stderr]    Compiling jobserver v0.1.34
[INFO] [stderr]     Checking http-body-util v0.1.3
[INFO] [stderr]     Checking symphonia-utils-xiph v0.5.5
[INFO] [stderr]     Checking symphonia-bundle-mp3 v0.5.5
[INFO] [stderr]     Checking symphonia-format-riff v0.5.5
[INFO] [stderr]     Checking parking_lot_core v0.9.12
[INFO] [stderr]     Checking errno v0.3.14
[INFO] [stderr]     Checking mio v1.1.1
[INFO] [stderr]     Checking socket2 v0.6.2
[INFO] [stderr]     Checking signal-hook-registry v1.4.8
[INFO] [stderr]     Checking symphonia-bundle-flac v0.5.5
[INFO] [stderr]    Compiling cc v1.2.54
[INFO] [stderr]     Checking num-traits v0.2.19
[INFO] [stderr]     Checking parking_lot v0.12.5
[INFO] [stderr]     Checking symphonia-format-ogg v0.5.5
[INFO] [stderr]     Checking rand v0.10.1
[INFO] [stderr]     Checking symphonia-codec-vorbis v0.5.5
[INFO] [stderr]     Checking symphonia-format-isomp4 v0.5.5
[INFO] [stderr]     Checking getrandom v0.3.4
[INFO] [stderr]     Checking seqlock v0.2.0
[INFO] [stderr]     Checking dashmap v6.1.0
[INFO] [stderr]     Checking num-integer v0.1.46
[INFO] [stderr]     Checking num-complex v0.4.6
[INFO] [stderr]     Checking ordered-float v3.9.2
[INFO] [stderr]     Checking uuid v1.20.0
[INFO] [stderr]     Checking num-bigint v0.4.6
[INFO] [stderr]     Checking transpose v0.2.3
[INFO] [stderr]     Checking primal-check v0.3.4
[INFO] [stderr]     Checking symphonia v0.5.5
[INFO] [stderr]     Checking rustfft v6.4.1
[INFO] [stderr]     Checking rand_distr v0.6.0
[INFO] [stderr]     Checking cookie v0.18.1
[INFO] [stderr]     Checking bitflags v2.10.0
[INFO] [stderr]     Checking alsa v0.11.0
[INFO] [stderr]    Compiling cmake v0.1.57
[INFO] [stderr]    Compiling aws-lc-sys v0.37.0
[INFO] [stderr]     Checking num-rational v0.4.2
[INFO] [stderr]    Compiling synstructure v0.13.2
[INFO] [stderr]    Compiling zerovec-derive v0.11.2
[INFO] [stderr]    Compiling displaydoc v0.2.5
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]    Compiling futures-macro v0.3.32
[INFO] [stderr]    Compiling serde_derive v1.0.228
[INFO] [stderr]    Compiling zerofrom-derive v0.1.6
[INFO] [stderr]    Compiling yoke-derive v0.8.1
[INFO] [stderr]    Compiling ptr_meta_derive v0.3.1
[INFO] [stderr]    Compiling thiserror-impl v2.0.18
[INFO] [stderr]    Compiling bytecheck_derive v0.8.2
[INFO] [stderr]     Checking futures-util v0.3.32
[INFO] [stderr]    Compiling munge_macro v0.4.7
[INFO] [stderr]     Checking tokio v1.49.0
[INFO] [stderr]     Checking ptr_meta v0.3.1
[INFO] [stderr]     Checking rancor v0.1.1
[INFO] [stderr]    Compiling pin-project-internal v1.1.11
[INFO] [stderr]    Compiling rkyv_derive v0.8.14
[INFO] [stderr]     Checking realfft v3.5.0
[INFO] [stderr]     Checking simple-eq v0.2.0 (https://github.com/m-hilgendorf/simple-eq.git#5875a795)
[INFO] [stderr]    Compiling strawberry_macros v0.1.0 (/opt/rustwide/workdir/strawberry_macros)
[INFO] [stderr]    Compiling async-trait v0.1.89
[INFO] [stderr]     Checking bytecheck v0.8.2
[INFO] [stderr]     Checking munge v0.4.7
[INFO] [stderr]     Checking rend v0.5.3
[INFO] [stderr]     Checking thiserror v2.0.18
[INFO] [stderr]     Checking rodio v0.22.2
[INFO] [stderr]     Checking pin-project v1.1.11
[INFO] [stderr]     Checking zerofrom v0.1.6
[INFO] [stderr]     Checking yoke v0.8.1
[INFO] [stderr]     Checking zerovec v0.11.5
[INFO] [stderr]     Checking zerotrie v0.2.3
[INFO] [stderr]     Checking tinystr v0.8.2
[INFO] [stderr]     Checking icu_locale_core v2.1.1
[INFO] [stderr]     Checking potential_utf v0.1.4
[INFO] [stderr]     Checking icu_collections v2.1.1
[INFO] [stderr]     Checking icu_provider v2.1.1
[INFO] [stderr]     Checking futures-executor v0.3.32
[INFO] [stderr]     Checking moka v0.12.13
[INFO] [stderr]     Checking icu_properties v2.1.2
[INFO] [stderr]     Checking icu_normalizer v2.1.1
[INFO] [stderr]     Checking futures v0.3.32
[INFO] [stderr]     Checking bincode v1.3.3
[INFO] [stderr]     Checking idna_adapter v1.2.1
[INFO] [stderr]     Checking idna v1.1.0
[INFO] [stderr]     Checking url v2.5.8
[INFO] [stderr]     Checking publicsuffix v2.3.0
[INFO] [stderr]     Checking tokio-util v0.7.18
[INFO] [stderr]     Checking tower v0.5.3
[INFO] [stderr]     Checking rodio_tap v0.2.0
[INFO] [stderr]     Checking rkyv v0.8.14
[INFO] [stderr]     Checking cookie_store v0.22.0
[INFO] [stderr]     Checking rkv v0.20.0
[INFO] [stderr]     Checking tower-http v0.6.8
[INFO] [stderr]     Checking h2 v0.4.13
[INFO] [stderr]     Checking tokio-stream v0.1.18
[INFO] [stderr]     Checking tokio-test v0.4.5
[INFO] [stderr]     Checking hyper v1.8.1
[INFO] [stderr]     Checking rustls-webpki v0.103.9
[INFO] [stderr]     Checking hyper-util v0.1.19
[INFO] [stderr]     Checking tokio-rustls v0.26.4
[INFO] [stderr]     Checking rustls-platform-verifier v0.6.2
[INFO] [stderr]     Checking hyper-rustls v0.27.7
[INFO] [stderr]     Checking reqwest v0.13.2
[INFO] [stderr]     Checking reqwest_cookie_store v0.10.0
[INFO] [stderr]     Checking strawberry_background v0.1.0 (/opt/rustwide/workdir)
[INFO] [stderr] pub struct CoordinatorConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub cycle_interval : Mutex < Option < Duration > > , pub
[INFO] [stderr]     queue_configuration_builder : Mutex < Option < QueueConfigurationBuilder >
[INFO] [stderr]     > ,
[INFO] [stderr] } impl CoordinatorConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new() -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             cycle_interval : Mutex :: new(None), queue_configuration_builder :
[INFO] [stderr]             Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_cycle_interval(& self, cycle_interval : Duration) -> &
[INFO] [stderr]     CoordinatorConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); * lock =
[INFO] [stderr]         Some(cycle_interval); self
[INFO] [stderr]     } pub fn take_cycle_interval(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_queue_configuration_builder(& self, queue_configuration_builder :
[INFO] [stderr]     QueueConfigurationBuilder) -> & CoordinatorConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.queue_configuration_builder.lock(); * lock =
[INFO] [stderr]         Some(queue_configuration_builder); self
[INFO] [stderr]     } pub fn take_queue_configuration_builder(& self) -> Option <
[INFO] [stderr]     QueueConfigurationBuilder >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.queue_configuration_builder.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct QueueConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub cycle_interval : Mutex < Option < Duration > > , pub max_request_count
[INFO] [stderr]     : Mutex < Option < usize > > , pub reject_strategy : Mutex < Option <
[INFO] [stderr]     RejectStrategy > > , pub wait_for_runner_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > , pub wait_for_queue_not_empty_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > , pub wait_for_queue_not_full_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > ,
[INFO] [stderr] } impl QueueConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new() -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             cycle_interval : Mutex :: new(None), max_request_count : Mutex ::
[INFO] [stderr]             new(None), reject_strategy : Mutex :: new(None),
[INFO] [stderr]             wait_for_runner_timeout : Mutex :: new(None),
[INFO] [stderr]             wait_for_queue_not_empty_timeout : Mutex :: new(None),
[INFO] [stderr]             wait_for_queue_not_full_timeout : Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_cycle_interval(& self, cycle_interval : Duration) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); * lock =
[INFO] [stderr]         Some(cycle_interval); self
[INFO] [stderr]     } pub fn take_cycle_interval(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn set_max_request_count(& self, max_request_count : usize) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_request_count.lock(); * lock =
[INFO] [stderr]         Some(max_request_count); self
[INFO] [stderr]     } pub fn take_max_request_count(& self) -> Option < usize >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_request_count.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn set_reject_strategy(& self, reject_strategy : RejectStrategy) ->
[INFO] [stderr]     & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.reject_strategy.lock(); * lock =
[INFO] [stderr]         Some(reject_strategy); self
[INFO] [stderr]     } pub fn take_reject_strategy(& self) -> Option < RejectStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.reject_strategy.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_runner_timeout(& self, wait_for_runner_timeout : Duration) ->
[INFO] [stderr]     & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_runner_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_runner_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_runner_timeout(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_runner_timeout.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_queue_not_empty_timeout(& self,
[INFO] [stderr]     wait_for_queue_not_empty_timeout : Duration) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_empty_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_queue_not_empty_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_queue_not_empty_timeout(& self) -> Option <
[INFO] [stderr]     Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_empty_timeout.lock(); let data
[INFO] [stderr]         = lock.take(); data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_queue_not_full_timeout(& self,
[INFO] [stderr]     wait_for_queue_not_full_timeout : Duration) -> & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_full_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_queue_not_full_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_queue_not_full_timeout(& self) -> Option < Duration
[INFO] [stderr]     >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_full_timeout.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct RunnerConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub identifier : Identifier, pub accepted_categories : Mutex < Option <
[INFO] [stderr]     Vec < String > > > ,
[INFO] [stderr] } impl RunnerConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new(identifier : Identifier,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             identifier : identifier, accepted_categories : Mutex ::
[INFO] [stderr]             new(Some(Vec :: new())),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn push_accepted_categories(& self, item : String) -> &
[INFO] [stderr]     RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); if lock.is_none()
[INFO] [stderr]         { * lock = Some(Vec :: new()); } let lock = lock.as_mut().unwrap();
[INFO] [stderr]         lock.push(item); self
[INFO] [stderr]     } pub fn clear_accepted_categories(& self) -> & RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); if lock.is_none()
[INFO] [stderr]         { return self; } let lock = lock.as_mut().unwrap(); lock.clear(); self
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_accepted_categories(& self, accepted_categories : Vec < String >) -> &
[INFO] [stderr]     RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); * lock =
[INFO] [stderr]         Some(accepted_categories); self
[INFO] [stderr]     } pub fn take_accepted_categories(& self) -> Option < Vec < String > >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct RequestBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub identifier : Identifier, pub priority : Mutex < Option < Priority > >
[INFO] [stderr]     , pub retry_strategy : Mutex < Option < RetryStrategy > > , pub
[INFO] [stderr]     post_retry_strategy : Mutex < Option < RetryStrategy > > , pub timeout :
[INFO] [stderr]     Mutex < Option < Duration > > , pub bytes : Mutex < Option < Bytes > > ,
[INFO] [stderr] } impl RequestBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new(identifier : Identifier,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             identifier : identifier, priority : Mutex :: new(None),
[INFO] [stderr]             retry_strategy : Mutex :: new(None), post_retry_strategy : Mutex
[INFO] [stderr]             :: new(None), timeout : Mutex :: new(None), bytes : Mutex ::
[INFO] [stderr]             new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_priority(& self, priority : Priority) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.priority.lock(); * lock = Some(priority); self } pub
[INFO] [stderr]     fn take_priority(& self) -> Option < Priority >
[INFO] [stderr]     { let mut lock = self.priority.lock(); let data = lock.take(); data } pub
[INFO] [stderr]     fn set_retry_strategy(& self, retry_strategy : RetryStrategy) -> &
[INFO] [stderr]     RequestBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.retry_strategy.lock(); * lock =
[INFO] [stderr]         Some(retry_strategy); self
[INFO] [stderr]     } pub fn take_retry_strategy(& self) -> Option < RetryStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.retry_strategy.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_post_retry_strategy(& self, post_retry_strategy : RetryStrategy) -> &
[INFO] [stderr]     RequestBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.post_retry_strategy.lock(); * lock =
[INFO] [stderr]         Some(post_retry_strategy); self
[INFO] [stderr]     } pub fn take_post_retry_strategy(& self) -> Option < RetryStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.post_retry_strategy.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     } pub fn set_timeout(& self, timeout : Duration) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.timeout.lock(); * lock = Some(timeout); self } pub
[INFO] [stderr]     fn take_timeout(& self) -> Option < Duration >
[INFO] [stderr]     { let mut lock = self.timeout.lock(); let data = lock.take(); data } pub
[INFO] [stderr]     fn set_bytes(& self, bytes : Bytes) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.bytes.lock(); * lock = Some(bytes); self } pub fn
[INFO] [stderr]     take_bytes(& self) -> Option < Bytes >
[INFO] [stderr]     { let mut lock = self.bytes.lock(); let data = lock.take(); data }
[INFO] [stderr] }
[INFO] [stderr] pub struct BaseRunnerBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub tokio_runtime : Arc < Runtime > , pub identifier : Identifier, pub
[INFO] [stderr]     configuration_builder : RunnerConfigurationBuilder, pub inner : Arc < dyn
[INFO] [stderr]     SimpleRunner > , pub max_concurrency_count : Mutex < Option < usize > > ,
[INFO] [stderr] } impl BaseRunnerBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn
[INFO] [stderr]     new(tokio_runtime : Arc < Runtime > , identifier : Identifier,
[INFO] [stderr]     configuration_builder : RunnerConfigurationBuilder, inner : Arc < dyn
[INFO] [stderr]     SimpleRunner > ,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             tokio_runtime : tokio_runtime, identifier : identifier,
[INFO] [stderr]             configuration_builder : configuration_builder, inner : inner,
[INFO] [stderr]             max_concurrency_count : Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_max_concurrency_count(& self, max_concurrency_count : usize)
[INFO] [stderr]     -> & BaseRunnerBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_concurrency_count.lock(); * lock =
[INFO] [stderr]         Some(max_concurrency_count); self
[INFO] [stderr]     } pub fn take_max_concurrency_count(& self) -> Option < usize >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_concurrency_count.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct CoordinatorConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub cycle_interval : Mutex < Option < Duration > > , pub
[INFO] [stderr]     queue_configuration_builder : Mutex < Option < QueueConfigurationBuilder >
[INFO] [stderr]     > ,
[INFO] [stderr] } impl CoordinatorConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new() -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             cycle_interval : Mutex :: new(None), queue_configuration_builder :
[INFO] [stderr]             Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_cycle_interval(& self, cycle_interval : Duration) -> &
[INFO] [stderr]     CoordinatorConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); * lock =
[INFO] [stderr]         Some(cycle_interval); self
[INFO] [stderr]     } pub fn take_cycle_interval(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_queue_configuration_builder(& self, queue_configuration_builder :
[INFO] [stderr]     QueueConfigurationBuilder) -> & CoordinatorConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.queue_configuration_builder.lock(); * lock =
[INFO] [stderr]         Some(queue_configuration_builder); self
[INFO] [stderr]     } pub fn take_queue_configuration_builder(& self) -> Option <
[INFO] [stderr]     QueueConfigurationBuilder >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.queue_configuration_builder.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct QueueConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub cycle_interval : Mutex < Option < Duration > > , pub max_request_count
[INFO] [stderr]     : Mutex < Option < usize > > , pub reject_strategy : Mutex < Option <
[INFO] [stderr]     RejectStrategy > > , pub wait_for_runner_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > , pub wait_for_queue_not_empty_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > , pub wait_for_queue_not_full_timeout : Mutex < Option <
[INFO] [stderr]     Duration > > ,
[INFO] [stderr] } impl QueueConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new() -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             cycle_interval : Mutex :: new(None), max_request_count : Mutex ::
[INFO] [stderr]             new(None), reject_strategy : Mutex :: new(None),
[INFO] [stderr]             wait_for_runner_timeout : Mutex :: new(None),
[INFO] [stderr]             wait_for_queue_not_empty_timeout : Mutex :: new(None),
[INFO] [stderr]             wait_for_queue_not_full_timeout : Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_cycle_interval(& self, cycle_interval : Duration) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); * lock =
[INFO] [stderr]         Some(cycle_interval); self
[INFO] [stderr]     } pub fn take_cycle_interval(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.cycle_interval.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn set_max_request_count(& self, max_request_count : usize) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_request_count.lock(); * lock =
[INFO] [stderr]         Some(max_request_count); self
[INFO] [stderr]     } pub fn take_max_request_count(& self) -> Option < usize >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_request_count.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn set_reject_strategy(& self, reject_strategy : RejectStrategy) ->
[INFO] [stderr]     & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.reject_strategy.lock(); * lock =
[INFO] [stderr]         Some(reject_strategy); self
[INFO] [stderr]     } pub fn take_reject_strategy(& self) -> Option < RejectStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.reject_strategy.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_runner_timeout(& self, wait_for_runner_timeout : Duration) ->
[INFO] [stderr]     & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_runner_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_runner_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_runner_timeout(& self) -> Option < Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_runner_timeout.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_queue_not_empty_timeout(& self,
[INFO] [stderr]     wait_for_queue_not_empty_timeout : Duration) -> &
[INFO] [stderr]     QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_empty_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_queue_not_empty_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_queue_not_empty_timeout(& self) -> Option <
[INFO] [stderr]     Duration >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_empty_timeout.lock(); let data
[INFO] [stderr]         = lock.take(); data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_wait_for_queue_not_full_timeout(& self,
[INFO] [stderr]     wait_for_queue_not_full_timeout : Duration) -> & QueueConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_full_timeout.lock(); * lock =
[INFO] [stderr]         Some(wait_for_queue_not_full_timeout); self
[INFO] [stderr]     } pub fn take_wait_for_queue_not_full_timeout(& self) -> Option < Duration
[INFO] [stderr]     >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.wait_for_queue_not_full_timeout.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct RunnerConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub identifier : Identifier, pub accepted_categories : Mutex < Option <
[INFO] [stderr]     Vec < String > > > ,
[INFO] [stderr] } impl RunnerConfigurationBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new(identifier : Identifier,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             identifier : identifier, accepted_categories : Mutex ::
[INFO] [stderr]             new(Some(Vec :: new())),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn push_accepted_categories(& self, item : String) -> &
[INFO] [stderr]     RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); if lock.is_none()
[INFO] [stderr]         { * lock = Some(Vec :: new()); } let lock = lock.as_mut().unwrap();
[INFO] [stderr]         lock.push(item); self
[INFO] [stderr]     } pub fn clear_accepted_categories(& self) -> & RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); if lock.is_none()
[INFO] [stderr]         { return self; } let lock = lock.as_mut().unwrap(); lock.clear(); self
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_accepted_categories(& self, accepted_categories : Vec < String >) -> &
[INFO] [stderr]     RunnerConfigurationBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); * lock =
[INFO] [stderr]         Some(accepted_categories); self
[INFO] [stderr]     } pub fn take_accepted_categories(& self) -> Option < Vec < String > >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.accepted_categories.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stderr] pub struct RequestBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub identifier : Identifier, pub priority : Mutex < Option < Priority > >
[INFO] [stderr]     , pub retry_strategy : Mutex < Option < RetryStrategy > > , pub
[INFO] [stderr]     post_retry_strategy : Mutex < Option < RetryStrategy > > , pub timeout :
[INFO] [stderr]     Mutex < Option < Duration > > , pub bytes : Mutex < Option < Bytes > > ,
[INFO] [stderr] } impl RequestBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn new(identifier : Identifier,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             identifier : identifier, priority : Mutex :: new(None),
[INFO] [stderr]             retry_strategy : Mutex :: new(None), post_retry_strategy : Mutex
[INFO] [stderr]             :: new(None), timeout : Mutex :: new(None), bytes : Mutex ::
[INFO] [stderr]             new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_priority(& self, priority : Priority) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.priority.lock(); * lock = Some(priority); self } pub
[INFO] [stderr]     fn take_priority(& self) -> Option < Priority >
[INFO] [stderr]     { let mut lock = self.priority.lock(); let data = lock.take(); data } pub
[INFO] [stderr]     fn set_retry_strategy(& self, retry_strategy : RetryStrategy) -> &
[INFO] [stderr]     RequestBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.retry_strategy.lock(); * lock =
[INFO] [stderr]         Some(retry_strategy); self
[INFO] [stderr]     } pub fn take_retry_strategy(& self) -> Option < RetryStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.retry_strategy.lock(); let data = lock.take();
[INFO] [stderr]         data
[INFO] [stderr]     } pub fn
[INFO] [stderr]     set_post_retry_strategy(& self, post_retry_strategy : RetryStrategy) -> &
[INFO] [stderr]     RequestBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.post_retry_strategy.lock(); * lock =
[INFO] [stderr]         Some(post_retry_strategy); self
[INFO] [stderr]     } pub fn take_post_retry_strategy(& self) -> Option < RetryStrategy >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.post_retry_strategy.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     } pub fn set_timeout(& self, timeout : Duration) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.timeout.lock(); * lock = Some(timeout); self } pub
[INFO] [stderr]     fn take_timeout(& self) -> Option < Duration >
[INFO] [stderr]     { let mut lock = self.timeout.lock(); let data = lock.take(); data } pub
[INFO] [stderr]     fn set_bytes(& self, bytes : Bytes) -> & RequestBuilder
[INFO] [stderr]     { let mut lock = self.bytes.lock(); * lock = Some(bytes); self } pub fn
[INFO] [stderr]     take_bytes(& self) -> Option < Bytes >
[INFO] [stderr]     { let mut lock = self.bytes.lock(); let data = lock.take(); data }
[INFO] [stderr] }
[INFO] [stderr] pub struct BaseRunnerBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub tokio_runtime : Arc < Runtime > , pub identifier : Identifier, pub
[INFO] [stderr]     configuration_builder : RunnerConfigurationBuilder, pub inner : Arc < dyn
[INFO] [stderr]     SimpleRunner > , pub max_concurrency_count : Mutex < Option < usize > > ,
[INFO] [stderr] } impl BaseRunnerBuilder
[INFO] [stderr] {
[INFO] [stderr]     pub fn
[INFO] [stderr]     new(tokio_runtime : Arc < Runtime > , identifier : Identifier,
[INFO] [stderr]     configuration_builder : RunnerConfigurationBuilder, inner : Arc < dyn
[INFO] [stderr]     SimpleRunner > ,) -> Self
[INFO] [stderr]     {
[INFO] [stderr]         Self
[INFO] [stderr]         {
[INFO] [stderr]             tokio_runtime : tokio_runtime, identifier : identifier,
[INFO] [stderr]             configuration_builder : configuration_builder, inner : inner,
[INFO] [stderr]             max_concurrency_count : Mutex :: new(None),
[INFO] [stderr]         }
[INFO] [stderr]     } pub fn set_max_concurrency_count(& self, max_concurrency_count : usize)
[INFO] [stderr]     -> & BaseRunnerBuilder
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_concurrency_count.lock(); * lock =
[INFO] [stderr]         Some(max_concurrency_count); self
[INFO] [stderr]     } pub fn take_max_concurrency_count(& self) -> Option < usize >
[INFO] [stderr]     {
[INFO] [stderr]         let mut lock = self.max_concurrency_count.lock(); let data =
[INFO] [stderr]         lock.take(); data
[INFO] [stderr]     }
[INFO] [stderr] }
[INFO] [stdout] warning: unused import: `crate::adapters::ffi::errors::FfiAdapterError`
[INFO] [stdout]  --> src/adapters/ffi/http/models.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::adapters::ffi::errors::FfiAdapterError;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::TryStreamExt`
[INFO] [stdout]  --> src/adapters/ffi/http/models.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use futures_util::TryStreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::panic::AssertUnwindSafe`
[INFO] [stdout]  --> src/adapters/ffi/service_exporter_ffi_adapter.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::panic::AssertUnwindSafe;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::domain::traits::monitor_traits::Monitor`
[INFO] [stdout]  --> src/adapters/ffi/service_exporter_ffi_adapter.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use crate::domain::traits::monitor_traits::Monitor;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/adapters/ffi/storage/models.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/domain/models/storage_models.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::Stream`
[INFO] [stdout]  --> src/domain/traits/http_traits.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use futures_util::Stream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ProgressReader`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:11:58
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::utils::progress_reader::{AsyncProgressReader, ProgressReader};
[INFO] [stdout]    |                                                          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Stream`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:14:20
[INFO] [stdout]    |
[INFO] [stdout] 14 | use futures_util::{Stream, StreamExt, TryStreamExt};
[INFO] [stdout]    |                    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io`
[INFO] [stdout]   --> src/infrastructure/http/cookie_backend.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::io;
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `MonitorHttpData`
[INFO] [stdout]   --> src/infrastructure/storage/storage_backend.rs:11:71
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::domain::models::monitor_models::{EventStage, MonitorEvent, MonitorHttpData, MonitorStorageData, Progress};
[INFO] [stdout]    |                                                                       ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::cell::OnceCell`
[INFO] [stdout]  --> src/monitor/monitor_service.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::cell::OnceCell;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicUsize` and `Ordering`
[INFO] [stdout]   --> src/service/service_runtime.rs:19:25
[INFO] [stdout]    |
[INFO] [stdout] 19 | use std::sync::atomic::{AtomicUsize, Ordering};
[INFO] [stdout]    |                         ^^^^^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::domain::traits::monitor_traits::Monitor`
[INFO] [stdout]  --> src/service/service_exporter.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::domain::traits::monitor_traits::Monitor;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `CycleSnapshot`
[INFO] [stdout]  --> src/superstructure/coordinator/registry.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 |     CycleSnapshot, Identifier, RegistryError,
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `EqualizerSource`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:3:73
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::superstructure::audio::audio_equalizer::{ArcEqualizerSource, EqualizerSource};
[INFO] [stdout]   |                                                                         ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `FftData` and `run_custom_visualizer`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:4:36
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::utils::fft_visualiser::{FftData, run_custom_visualizer};
[INFO] [stdout]   |                                    ^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:8:19
[INFO] [stdout]   |
[INFO] [stdout] 8 | use parking_lot::{Mutex, RwLock};
[INFO] [stdout]   |                   ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::runtime::Runtime`
[INFO] [stdout]   --> src/superstructure/audio/audio_player.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use tokio::runtime::Runtime;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::task::JoinHandle`
[INFO] [stdout]   --> src/superstructure/audio/audio_player.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | use tokio::task::JoinHandle;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `SeekFrom` and `Seek`
[INFO] [stdout]  --> src/superstructure/audio/audio_equalizer.rs:1:15
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::io::{Seek, SeekFrom};
[INFO] [stdout]   |               ^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/superstructure/audio/audio_equalizer.rs:2:19
[INFO] [stdout]   |
[INFO] [stdout] 2 | use parking_lot::{Mutex, RwLock};
[INFO] [stdout]   |                   ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::adapters::ffi::errors::FfiAdapterError`
[INFO] [stdout]  --> src/adapters/ffi/http/models.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::adapters::ffi::errors::FfiAdapterError;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::TryStreamExt`
[INFO] [stdout]  --> src/adapters/ffi/http/models.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use futures_util::TryStreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::panic::AssertUnwindSafe`
[INFO] [stdout]  --> src/adapters/ffi/service_exporter_ffi_adapter.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::panic::AssertUnwindSafe;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::domain::traits::monitor_traits::Monitor`
[INFO] [stdout]  --> src/adapters/ffi/service_exporter_ffi_adapter.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use crate::domain::traits::monitor_traits::Monitor;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/adapters/ffi/storage/models.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/domain/models/storage_models.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::Stream`
[INFO] [stdout]  --> src/domain/traits/http_traits.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use futures_util::Stream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ProgressReader`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:11:58
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::utils::progress_reader::{AsyncProgressReader, ProgressReader};
[INFO] [stdout]    |                                                          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Stream`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:14:20
[INFO] [stdout]    |
[INFO] [stdout] 14 | use futures_util::{Stream, StreamExt, TryStreamExt};
[INFO] [stdout]    |                    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io`
[INFO] [stdout]   --> src/infrastructure/http/cookie_backend.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::io;
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `MonitorHttpData`
[INFO] [stdout]   --> src/infrastructure/storage/storage_backend.rs:11:71
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::domain::models::monitor_models::{EventStage, MonitorEvent, MonitorHttpData, MonitorStorageData, Progress};
[INFO] [stdout]    |                                                                       ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::cell::OnceCell`
[INFO] [stdout]  --> src/monitor/monitor_service.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::cell::OnceCell;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicUsize` and `Ordering`
[INFO] [stdout]   --> src/service/service_runtime.rs:19:25
[INFO] [stdout]    |
[INFO] [stdout] 19 | use std::sync::atomic::{AtomicUsize, Ordering};
[INFO] [stdout]    |                         ^^^^^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::domain::traits::monitor_traits::Monitor`
[INFO] [stdout]  --> src/service/service_exporter.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::domain::traits::monitor_traits::Monitor;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Priority`
[INFO] [stdout]   --> src/service/service_exporter.rs:32:65
[INFO] [stdout]    |
[INFO] [stdout] 32 |         CategorizerError, CoordinatorConfiguration, Identifier, Priority, Request,
[INFO] [stdout]    |                                                                 ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::ops::Deref`
[INFO] [stdout]   --> src/service/service_exporter.rs:49:9
[INFO] [stdout]    |
[INFO] [stdout] 49 |     use std::ops::Deref;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `CycleSnapshot`
[INFO] [stdout]  --> src/superstructure/coordinator/registry.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 |     CycleSnapshot, Identifier, RegistryError,
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `EqualizerSource`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:3:73
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::superstructure::audio::audio_equalizer::{ArcEqualizerSource, EqualizerSource};
[INFO] [stdout]   |                                                                         ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `FftData` and `run_custom_visualizer`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:4:36
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::utils::fft_visualiser::{FftData, run_custom_visualizer};
[INFO] [stdout]   |                                    ^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/superstructure/audio/audio_player.rs:8:19
[INFO] [stdout]   |
[INFO] [stdout] 8 | use parking_lot::{Mutex, RwLock};
[INFO] [stdout]   |                   ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::runtime::Runtime`
[INFO] [stdout]   --> src/superstructure/audio/audio_player.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use tokio::runtime::Runtime;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::task::JoinHandle`
[INFO] [stdout]   --> src/superstructure/audio/audio_player.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | use tokio::task::JoinHandle;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::StreamExt`
[INFO] [stdout]    --> src/superstructure/audio/audio_player.rs:253:9
[INFO] [stdout]     |
[INFO] [stdout] 253 |     use futures_util::StreamExt;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::fs::OpenOptions`
[INFO] [stdout]    --> src/superstructure/audio/audio_player.rs:256:9
[INFO] [stdout]     |
[INFO] [stdout] 256 |     use std::fs::OpenOptions;
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Write`
[INFO] [stdout]    --> src/superstructure/audio/audio_player.rs:257:25
[INFO] [stdout]     |
[INFO] [stdout] 257 |     use std::io::{Read, Write};
[INFO] [stdout]     |                         ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused macro definition: `await_test`
[INFO] [stdout]    --> src/superstructure/audio/audio_player.rs:262:18
[INFO] [stdout]     |
[INFO] [stdout] 262 |     macro_rules! await_test {
[INFO] [stdout]     |                  ^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_macros)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `SeekFrom` and `Seek`
[INFO] [stdout]  --> src/superstructure/audio/audio_equalizer.rs:1:15
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::io::{Seek, SeekFrom};
[INFO] [stdout]   |               ^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/superstructure/audio/audio_equalizer.rs:2:19
[INFO] [stdout]   |
[INFO] [stdout] 2 | use parking_lot::{Mutex, RwLock};
[INFO] [stdout]   |                   ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `StreamExt`
[INFO] [stdout]  --> src/utils/stream_with_callback.rs:1:36
[INFO] [stdout]   |
[INFO] [stdout] 1 | use futures_util::stream::{Stream, StreamExt};
[INFO] [stdout]   |                                    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `StreamExt`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:14:28
[INFO] [stdout]    |
[INFO] [stdout] 14 | use futures_util::{Stream, StreamExt, TryStreamExt};
[INFO] [stdout]    |                            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]   --> src/infrastructure/http/cookie_backend.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use tokio::io::AsyncWriteExt;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `StreamExt`
[INFO] [stdout]   --> src/infrastructure/http/reqwest_backend.rs:14:28
[INFO] [stdout]    |
[INFO] [stdout] 14 | use futures_util::{Stream, StreamExt, TryStreamExt};
[INFO] [stdout]    |                            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `StreamExt`
[INFO] [stdout]  --> src/utils/stream_with_callback.rs:1:36
[INFO] [stdout]   |
[INFO] [stdout] 1 | use futures_util::stream::{Stream, StreamExt};
[INFO] [stdout]   |                                    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]   --> src/infrastructure/http/cookie_backend.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use tokio::io::AsyncWriteExt;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:346:31
[INFO] [stdout]     |
[INFO] [stdout] 346 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:318:31
[INFO] [stdout]     |
[INFO] [stdout] 318 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:356:31
[INFO] [stdout]     |
[INFO] [stdout] 356 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:302:69
[INFO] [stdout]     |
[INFO] [stdout] 302 |         let response = self.do_execute(endpoint).await.inspect_err(|e| {
[INFO] [stdout]     |                                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:389:69
[INFO] [stdout]     |
[INFO] [stdout] 389 |         let response = self.do_execute(endpoint).await.inspect_err(|e| {
[INFO] [stdout]     |                                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/infrastructure/storage/storage_backend.rs:95:27
[INFO] [stdout]    |
[INFO] [stdout] 95 |             .inspect_err(|e| {
[INFO] [stdout]    |                           ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:346:31
[INFO] [stdout]     |
[INFO] [stdout] 346 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:318:31
[INFO] [stdout]     |
[INFO] [stdout] 318 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:356:31
[INFO] [stdout]     |
[INFO] [stdout] 356 |                 .inspect_err(|e| {
[INFO] [stdout]     |                               ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:302:69
[INFO] [stdout]     |
[INFO] [stdout] 302 |         let response = self.do_execute(endpoint).await.inspect_err(|e| {
[INFO] [stdout]     |                                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/http/reqwest_backend.rs:389:69
[INFO] [stdout]     |
[INFO] [stdout] 389 |         let response = self.do_execute(endpoint).await.inspect_err(|e| {
[INFO] [stdout]     |                                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/storage/storage_backend.rs:147:27
[INFO] [stdout]     |
[INFO] [stdout] 147 |             .inspect_err(|e| {
[INFO] [stdout]     |                           ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/infrastructure/storage/storage_backend.rs:95:27
[INFO] [stdout]    |
[INFO] [stdout] 95 |             .inspect_err(|e| {
[INFO] [stdout]    |                           ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/infrastructure/storage/storage_backend.rs:147:27
[INFO] [stdout]     |
[INFO] [stdout] 147 |             .inspect_err(|e| {
[INFO] [stdout]     |                           ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `tag`
[INFO] [stdout]    --> src/superstructure/file_cache_backend.rs:360:27
[INFO] [stdout]     |
[INFO] [stdout] 360 |     async fn flush(&self, tag: &String) -> Result<(), CacheError> {
[INFO] [stdout]     |                           ^^^ help: if this is intentional, prefix it with an underscore: `_tag`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `tokio_runtime`
[INFO] [stdout]    --> src/service/service_exporter.rs:350:13
[INFO] [stdout]     |
[INFO] [stdout] 350 |         let tokio_runtime = service_runtime.tokio_runtime.clone();
[INFO] [stdout]     |             ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_tokio_runtime`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `watcher`
[INFO] [stdout]    --> src/service/service_exporter.rs:526:44
[INFO] [stdout]     |
[INFO] [stdout] 526 |         fn submit(&self, request: Request, watcher: Arc<dyn RunnerWatcher>) -> Result<(), RunnerError> {
[INFO] [stdout]     |                                            ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_watcher`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `tag`
[INFO] [stdout]    --> src/superstructure/file_cache_backend.rs:360:27
[INFO] [stdout]     |
[INFO] [stdout] 360 |     async fn flush(&self, tag: &String) -> Result<(), CacheError> {
[INFO] [stdout]     |                           ^^^ help: if this is intentional, prefix it with an underscore: `_tag`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/utils/url_component.rs:80:53
[INFO] [stdout]    |
[INFO] [stdout] 80 |     let parsed = Url::parse(&url_to_parse).map_err(|e| UrlParseError::ParseError)?;
[INFO] [stdout]    |                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `tokio_runtime`, `sender`, and `receiver` are never read
[INFO] [stdout]   --> src/infrastructure/monitor/mpsc_monitor_backend.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | pub struct MpscMonitorBackend {
[INFO] [stdout]    |            ------------------ fields in this struct
[INFO] [stdout] 11 |     tokio_runtime: Arc<Runtime>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 12 |     self_weak: Mutex<Weak<MpscMonitorBackend>>,
[INFO] [stdout] 13 |     sender: Sender<MonitorEvent>,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 14 |     receiver: Receiver<MonitorEvent>,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `runtime`
[INFO] [stdout]    --> src/superstructure/audio/audio_player.rs:270:13
[INFO] [stdout]     |
[INFO] [stdout] 270 |         let runtime = Arc::new(Runtime::new().unwrap());
[INFO] [stdout]     |             ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_runtime`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/utils/url_component.rs:80:53
[INFO] [stdout]    |
[INFO] [stdout] 80 |     let parsed = Url::parse(&url_to_parse).map_err(|e| UrlParseError::ParseError)?;
[INFO] [stdout]    |                                                     ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `tokio_runtime`, `sender`, and `receiver` are never read
[INFO] [stdout]   --> src/infrastructure/monitor/mpsc_monitor_backend.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | pub struct MpscMonitorBackend {
[INFO] [stdout]    |            ------------------ fields in this struct
[INFO] [stdout] 11 |     tokio_runtime: Arc<Runtime>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 12 |     self_weak: Mutex<Weak<MpscMonitorBackend>>,
[INFO] [stdout] 13 |     sender: Sender<MonitorEvent>,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 14 |     receiver: Receiver<MonitorEvent>,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 11s
[INFO] running `Command { std: "docker" "inspect" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0", kill_on_drop: false }`
[INFO] [stdout] 6b00d4b4ef8861057d2da6acd577a386e6c80a021bd14cb73b6855570c235de0
